package com.hefei.garden.service.impl;

import com.hefei.garden.config.kafka.annotation.KafkaTopicStrategy;
import com.hefei.garden.service.KafkaTopicStrategyService;
import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * @author: devil
 * @Date: 2022/10/6 22
 * @Description:
 */
@KafkaTopicStrategy(topic = "topic-demo", groupId = "group-id-1")
public class DemoTopicStrategyServiceImpl implements KafkaTopicStrategyService {

    @Override
    public void businessProcess(ConsumerRecord<String, String> records) {
        System.out.println("group-id-1: " + records);
    }

}
